package com.syl.qianyin.spider.exend;

import org.springframework.data.redis.core.RedisTemplate;
import us.codecraft.webmagic.ResultItems;
import us.codecraft.webmagic.Task;
import us.codecraft.webmagic.pipeline.Pipeline;

/**
 * @author syl
 * @create 2019-05-11 13:35
 **/
public class MergeConsolePipeline implements Pipeline {

    private RedisTemplate redisTemplate;

    public MergeConsolePipeline(String key){

    }

    @Override
    public void process(ResultItems resultItems, Task task) {
//        Set<String> keys = RedisUtils.getAvMooMapOps(redisTemplate).keys(RedisKeyConstant.MAP_MOO_DATA_KEY);
//        for (String key : keys) {
//            AvMooBean avMooBean = RedisUtils.getAvMooMapOps(redisTemplate).get(RedisKeyConstant.MAP_MOO_DATA_KEY, key);
//            System.out.println(avMooBean);
//        }
    }

}
